package net.xo68.destiny.starter.worker.handler;

import net.xo68.destiny.contract.domain.report.JobHandleReplyDatagram;

import java.util.List;

/***
 * 任务处理状态回复失败信息存储
 * @author wuxie
 * @version 2020-12-8
 */
public interface JobHandleReplyFailStore {

    /**
     * 取失败的前多条信息
     * @param limit
     * @return
     */
    List<JobHandleReplyDatagram> limit(long limit);

    /**
     * 移除重试成功的任务处理状态信息
     * @param eventList
     */
    void remove(final List<JobHandleReplyDatagram> eventList);

    /**
     * 加入回复失败的任务处理状态信息
     * @param eventList
     */
    void batchAdd(final List<JobHandleReplyDatagram> eventList );
}
